package com.sh.data.engine.infrastructure.config;

import lombok.Data;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;

/**
 * @author: mengzheng.mhc
 * @date: 2024/7/1 17:23
 */
@Data
@Configuration
@ConfigurationProperties(prefix = "data.engine.flink-config")
public class FlinkConfig {

    private String command =
        "/data/flink/flink-1.19.1/bin/flink run -c com.sh.data.engine.flink.client.FlinkClient /data/flink/data-engine-flink-task-client.jar $1 $2";

    private String home = "/data/flink/flink-1.19.1/bin/";

    private String port = "16001";

    private String flinkDir = "/data/flink/flink-1.19.1/log";

    private String csvDir = "/data/data_engine_file_storage/flink_csv";

    private final String flinkLog = "/data/data_engine_file_storage/log/flink";
}
